74a63d31ed388b4cca7c66decb12a6431097247d,jobqueue/src/main/java/com/birbit/android/jobqueue/ConsumerManager.java,ConsumerManager,addWorker,#,145
Before Change
Consumer consumer = new Consumer(jobManagerThread.messageQueue,
new SafeMessageQueue(timer, factory, "consumer"), factory, timer);
Thread thread = new Thread(threadGroup, consumer, "job-queue-worker-" + UUID.randomUUID());
thread.setPriority(threadPriority);
consumers.add(consumer);
thread.start();
}
After Change
if (threadFactory != null) {
thread = threadFactory.newThread(consumer);
} else {
thread = new Thread(threadGroup, consumer, "job-queue-worker-" + UUID.randomUUID());
thread.setPriority(threadPriority);
}
consumers.add(consumer);
thread.start();